package com.cndcare.msc.netty.rocketmq.client;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

public interface StreamClient {

    String BIND_ALARM_MQ_NETTY_ALARM = "bindAlarmMqNettyAlarm";

    @Input(StreamClient.BIND_ALARM_MQ_NETTY_ALARM)
    SubscribableChannel inputBindAlarmMqNettyAlarm();
}
